import deal.SendJsonToHdfs;
import deal.SplitJsonFileByCKSJ;

public class RunEltData {
    public static void main(String[] args) {
        SplitJsonFileByCKSJ.run();
        //将数据发送给hdfs
        //当前时间节点前数据
//            SendJsonToHdfs.send("test/outSZ1.json","hdfs://192.168.88.131:8020/ETC/outSZ1.json");
            SendJsonToHdfs.send("test/inSZ1.json","hdfs://192.168.88.131:8020/ETC/inSZ1/inSZ1.json");
//            SendJsonToHdfs.send("test/outSZ2.json","hdfs://192.168.88.131:8020/ETC/outSZ2.json");
//            SendJsonToHdfs.send("test/inSZ2.json","hdfs://192.168.88.131:8020/ETC/inSZ2.json");
    }
}
